package com.zhaosc.spark.core.broadcast

import org.apache.spark.SparkConf
import org.apache.spark.SparkContext

object BroadcastOperation {

  def main(args: Array[String]): Unit = {

    val conf = new SparkConf().setMaster("local")
      .setAppName("BroadcastOperation");
    val sc = new SparkContext(conf);
    
    val blackList=Array("wangfei","zhaosc")
    val nameList = Array(
      new Tuple2(1, "xuruyun"),
      new Tuple2(2, "liangyongqi"),
       new Tuple2(3, "wangfei"),
      new Tuple2(4, "zhaosc"));
    
    sc.parallelize(nameList);
  }
}